'use strict';
const mysql = require('mysql');
const config = require("../config/mysql");
const pool = mysql.createPool(config.DB);
const mgPool = mysql.createPool(config.MG);
/** 查询数据库 */
exports.query = function(sql, rfun, para = []){
    pool.query(sql, para, (err, res, fields) => {
        if (err) {
            LOG.error('mysql', sql, para, err);
            return rfun && rfun(null);
        }
        rfun && rfun(res);
    })
}
/** 查询日志库 */
exports.queryMg = function(sql, rfun, para = []){
    mgPool.query(sql, para, (err, res, fields) => {
        if (err) {
            LOG.error('mysql', sql, para, err);
            return rfun && rfun(null);
        }
        rfun && rfun(res);
    })
}
/** 准备语句 */
exports.format = function(sql, para){
    return mysql.format(sql, para);
}
